/*  1:   */ package org.jetbrains.debugger;
/*  2:   */ 
/*  3:   */

import com.intellij.util.Consumer;
import org.jetbrains.annotations.NotNull;

/*  4:   */
/*  5:   */ 
/*  6:   */ public abstract class ContextDependentAsyncResultConsumer<T>
/*  7:   */   implements Consumer<T>
/*  8:   */ {
/*  9:   */   protected final SuspendContext context;
/* 10:   */   
/* 11:   */   public ContextDependentAsyncResultConsumer(@NotNull SuspendContext paramSuspendContext)
/* 12:   */   {
/* 13:10 */     this.context = paramSuspendContext;
/* 14:   */   }
/* 15:   */   
/* 16:   */   public final void consume(T paramT)
/* 17:   */   {
/* 18:15 */     Vm localVm = this.context.getVm();
/* 19:16 */     if ((localVm.isAttached()) && (!localVm.getSuspendContextManager().isContextObsolete(this.context))) {
/* 20:17 */       consume(paramT, localVm);
/* 21:   */     }
/* 22:   */   }
/* 23:   */   
/* 24:   */   protected abstract void consume(T paramT, @NotNull Vm paramVm);
/* 25:   */ }



/* Location:           E:\idea\

 * Qualified Name:     org.jetbrains.debugger.ContextDependentAsyncResultConsumer

 * JD-Core Version:    0.7.0.1

 */